package site.icesky.springboot.rocketmq.mqconsumer;

import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;

/**
 * @ClassName: RocketMqConsumer <br>
 * @Description: MQ消费者实现接口 <br>
 * @Package: site.icesky.springboot.rocketmq.config <br>
 * @author: suitianmou <br>
 * @Date: 2020/5/23-19:46 <br>
 * @version: 1.0 <br>
 * @see <br>
 * @since (从产品的哪一个版本此类被添加进来 ( 可选))<br>
 * 修改历史: <br>
 * 修改时间             修改人           版本变更           修改说明<br>
 * -----------------------------------------------------<br>
 * <br>
 */
public interface RocketMqConsumer {

    public abstract void init();

    public void registerMessageListener(MessageListenerConcurrently messageListener);
}
